package org.xi.maple.api

import org.apache.spark.sql.{Dataset, Row, SparkSession}

import scala.collection.mutable

trait MapleSink[T <: SinkConfig] extends MaplePlugin[T] {
  def output(spark: SparkSession, argsMap: mutable.Map[String, String], data: Dataset[Row]): Unit
}